package com.qit.prototype.flink;

import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.List;
import java.util.Map;

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.cep.CEP;
import org.apache.flink.cep.PatternFlatSelectFunction;
import org.apache.flink.cep.PatternStream;
import org.apache.flink.cep.functions.PatternProcessFunction;
import org.apache.flink.cep.pattern.Pattern;
import org.apache.flink.cep.pattern.conditions.SimpleCondition;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.util.Collector;

import com.qit.prototype.flink.entity.Tick;
import com.qit.prototype.flink.performance.TestCase1;
import com.qit.prototype.flink.performance.TestCase2;
import com.qit.prototype.flink.performance.TestCase3;
import com.qit.prototype.flink.performance.TestCase4;
import com.qit.prototype.flink.performance.TestCase5;
import com.qit.prototype.flink.performance.TestCase6;
import com.qit.prototype.flink.performance.TestCase7;
import com.qit.prototype.flink.performance.TestCase8;
import com.qit.prototype.flink.performance.TestCase9;

/**
 * 
 *
 */
public class App {
	
	public static void main(String[] args) throws Exception {
		try {
//			TestCase1 tc1 = new TestCase1();
//			TestCase2 tc2 = new TestCase2();
//			TestCase3 tc3 = new TestCase3();
//			TestCase4 tc4 = new TestCase4();
//			TestCase5 tc5 = new TestCase5();
//			TestCase6 tc6 = new TestCase6();
//			TestCase7 tc7 = new TestCase7();
//			TestCase8 tc8 = new TestCase8();
			TestCase9 tc9 = new TestCase9();
		}
		catch (Exception e) {
			
		}
		
	}
	

	
}
